Skip to content

[feat][backend] trace ingestion refactor#469

Open
cuichen01 wants to merge 10 commits intomainfrom
ft_cc_ingestion_refactor_2
Open

[feat][backend] trace ingestion refactor#469
cuichen01 wants to merge 10 commits intomainfrom
ft_cc_ingestion_refactor_2

Conversation

@cuichen01
Copy link
Copy Markdown
Collaborator

What type of PR is this?

Check the PR title

  • This PR title match the format: [<type>][<scope>] <description>. For example: [fix][backend] flaky fix
  • The description of this PR title is user-oriented and clear enough for others to understand.
  • Add documentation if the current PR requires user awareness at the usage level.
  • This PR is written in English. PRs not in English will not be reviewed.

(Optional) Translate the PR title into Chinese

(Optional) More detailed description for this PR(en: English/zh: Chinese)

en:
zh(optional):

(Optional) Which issue(s) this PR fixes

…s duration per node

- Add ObserveConsumer decorator that wraps node consumers to measure self-only duration
- Add stopwatchConsumer to track downstream elapsed time (total - downstream = self)
- Integrate into Graph.buildComponents for Receiver, Processor, and Exporter nodes
- Plumb ConsumeMetric through Collector -> Service -> Graph via Settings
- Register trace_consume metric in observability infra metrics
- Update wire DI to provide ConsumeMetric
- Add SpansCountByPSM to group spans by PSM for per-PSM metric emission
- Emit metrics grouped by tenant/psm dimensions
- Define metric tag and suffix constants in infra/metrics package
- Update observe_consumer to reference centralized constants
…lteredCount

- Add SpanStats context utilities: InjectSpanCounts, AddFilteredSpans, GetSpanStatsEntries, GetSpanStatsEntry
- FilteredCount is map[string]int keyed by pipeline name, supporting independent filtering per exporter pipeline
- Add InjectConsumer decorator to auto-inject span counts at Receiver entry
- Wire InjectConsumer into graph building for Receiver nodes
- Add comprehensive tests for SpanStats and InjectConsumer
… SpanStats

- Add OutCount map[string]int to SpanStatsEntry, keyed by pipeline name
- Add AddOutCountSpans function mirroring AddFilteredSpans pattern
- Add TotalOutCount and GetOutCount accessor methods
- Add tests for OutCount by pipeline, accumulation, and new entry creation
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant